package com.zliuyno.rpcdemo.transport;


import com.zliuyno.rpcdemo.util.Packmsg;
import com.zliuyno.rpcdemo.rpc.ResponseMappingCallback;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;

public class ClientResponses extends ChannelInboundHandlerAdapter {

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        Packmsg responsepkg = (Packmsg) msg;
        //曾经没考虑返回的事
        ResponseMappingCallback.runCallBack(responsepkg);

    }
}